"""
实验接收redis信息
"""
# 导入模块
import redis

# 创建链接
client = redis.StrictRedis(password='123456')


def set_msg():
    msg = input("请输入要发送的信息：")
    while True:
        client.publish('sb', msg)
        print("""
                1、继续发送信息
                2、退出信息发送
                """)
        num = input("请输入选择：")
        if num == '1':
            msg = input("请输入要发送的信息：")
        elif num == '2':
            break
        else:
            print('输入不合法')


# 重复发送信息到指定频道
while True:
    print("""
    1、发送信息
    2、退出程序
    """)
    num = input("请输入您的选择：")
    if num == '1':
        set_msg()
    elif num == '2':
        break
    else:
        print("输入错误,请重新输入")


# 释放资源
client.close()
